const mysql = require('mysql');
/**
 * 函数：1>函数参数  2>函数的功能  3>函数的返回值  4>函数何时调用
 * */ 
module.exports = (sql,params=[]) => {
    //1.创建链接对象
    let connection = mysql.createConnection({
        host:'localhost',
        port:3306,  //可有可无
        user:'root',
        password:'root',
        database:'1709b-userlist'
    })
    //2.链接数据库
    connection.connect((error) => {
        if(error){
            console.log("数据库连接失败")
        }else{
            console.log("数据库连接成功")
        }
    })

    //3.和数据库进行交互   异步的
    return new Promise((resolve,reject) => {
        // query  第一个参数  sql语句  第二个参数：传递的参数
        connection.query(sql,params,(error,data) => {
            if(error){
                reject(error);
            }else{
                resolve(data);
            }
            //4.关闭链接
            connection.end();
        })
    })
}